package com.xxk.rocket.star.core.dto;

import com.alibaba.rocketmq.common.consumer.ConsumeFromWhere;
import lombok.Data;

@Data
public class StargateConsumeBaseDTO {

  private boolean broadcasting;
  private int pullBatchSize;
  private ConsumeFromWhere consumeFromWhere;

}
